package com.kafka.dao;

import java.util.Map;

import org.apache.ibatis.annotations.Param;

import com.kafka.bean.Message;

public interface MessageMapper {
	public void insertMessageInfo(@Param(value="message")Message message);
	public int selectByParam(Map<?, ?> map);
}
